package datasource

import org.apache.flink.streaming.api.scala._

object FileStream {
  /**
    * 从文件获取数据源
    * @param path
    * @param env
    * @return
    */
  def getFileStream(path: String, env: StreamExecutionEnvironment): DataStream[String] = {
    env.readTextFile(path)
  }

}
